import os
import sys
HOME_PATH = os.path.join(
    os.path.dirname(os.path.dirname(os.path.abspath(__file__))),
    'src/')
sys.path.append(HOME_PATH)
from rabbitmqpy import Puber

# 测试
amqp_url = 'amqp://10.12.3.162:31911'
# amqp_url = 'amqp://10.12.3.162:32037'

puber = Puber(
    amqp_url,
    'shuiqing_test',
    'direct',
    routing_key='shuiqing_key1'
)

puber.send("hellp")

